//package com.yfp.org.job;
//
//import cn.hutool.core.date.DateUtil;
//import cn.hutool.http.HttpUtil;
//import cn.hutool.json.JSONObject;
//import com.alibaba.fastjson2.JSON;
//import com.google.gson.Gson;
//import com.yfp.common.core.domain.R;
//import entity.domain.com.yfp.org.OrderList;
//import entity.domain.com.yfp.org.RefundInfo;
//import entity.domain.com.yfp.org.RefundResult;
//import entity.domain.com.yfp.org.Wapper;
//import mapper.com.yfp.org.OrderComboMapper;
//import mapper.com.yfp.org.OrderListMapper;
//import util.com.yfp.org.ClientUtils;
//import jakarta.annotation.Resource;
//import lombok.extern.slf4j.Slf4j;
//import org.springframework.beans.factory.annotation.Value;
//import org.springframework.scheduling.annotation.Scheduled;
//import org.springframework.stereotype.Component;
//
//import java.util.*;
//
///**
// * @PROJECT_NAME: ydyfp
// * @DESCRIPTION:
// * @USER: xiaohuya
// * @DATE: 2024/1/5 16:48
// */
//@Component
//@Slf4j
//
//public class OrderJob {
//    @Value("${MiniProgram.OrderUrl}")
//    private String orderUrl;
//    @Resource
//    private OrderListMapper orderListMapper;
//    @Resource
//    private OrderComboMapper orderComboMapper;
//
//    @Scheduled(cron = "*/50 * * * * ?")
//    public void doTask() {
//        OrderList orderList = new OrderList();
//        orderList.setPayStatus(6);
//        List<OrderList> orderLists = orderListMapper.queryAllByLimit(orderList);
//        if (!orderLists.isEmpty()) {
//            try {
//
//
//            orderLists.forEach(e -> {
//                if (e.getPayStatus()==6){
//                    log.info("退款订单号：{}",e.getOrderSn());
//                    log.info("退款单号：{}",e.getRefundSn());
//                    JSONObject jsonParam = new JSONObject();
//                    jsonParam.put("item_order_num", e.getOrderSn());
//                    jsonParam.put("refund_order_num", e.getRefundSn());
//                    String result = HttpUtil.get(orderUrl, jsonParam);
//                    Gson gson = new Gson();
//                    log.info("小程序返回：{}",result);
//                    HashMap hashMap = gson.fromJson(result, HashMap.class);
//                    if (hashMap == null) {
//
//                        log.info("小程序接口返回有误{}",hashMap);
//                    }
//
//                    if (hashMap.get("status").equals("pay.200")) {
//                        Object payload = hashMap.get("payload");
//
//                        HashMap hashMap1 = gson.fromJson(payload.toString(), HashMap.class);
//                        if ((Boolean) hashMap1.get("isRefund")){
//                            e.setPayStatus(4);
//                            e.setRefundTime(new Date());
//                            this.orderComboMapper.updateRefund(e.getOrderSn());
//                        }
//
//                    } else {
//                        e.setPayStatus(9);
//                    }
//
//                    log.info("入库数据{}",e);
//                    orderListMapper.updateRefund(e);
//                }
//
//
//            });
//
//            }catch (Exception e){
//                e.printStackTrace();
//                log.info("小程序接口返回有误");
//
//            }
//
//        }
//
//
//
//        // 在这里添加你的任务代码
//    }
//
//    public static void main(String[] args) {
//        JSONObject jsonParam = new JSONObject();
//        jsonParam.put("item_order_num", 1);
////        jsonParam.put("refund_order_num", 1);
//        String result = HttpUtil.get("https://test-pay.qafanle.com/pay/rpc/order/refund/status", jsonParam);
//        Gson gson = new Gson();
//        log.info("小程序返回：{}",result);
//    }
//}